package com.dtwave.param;
import lombok.*;

import java.io.Serializable;
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class KafkaParamsObj implements Serializable {
    @NonNull
    private String kafkaUrl;
    @NonNull
    private String dataFrom;
    @NonNull
    private String groupId;
    @NonNull
    private String oggTopic;
    @NonNull
    private String startUpModule;
    @NonNull
    private String startTimestamp;

    @Override
    public String toString() {
        return "kafka参数信息"+
                "kafkaUrl"+kafkaUrl+
                "dataFrom"+dataFrom+
                "groupId"+groupId+
                "oggTopic"+oggTopic+
                "startUpModule"+startUpModule+
                "startTimestamp"+startTimestamp+"}";
    }
}
